package DAO;


import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import DBConection.ConexionBD;
import Modelo.*;

public class CombustibleDao {

	private Connection conn;

	public CombustibleDao() {
		conn = ConexionBD.getConnection();
	}

	public void addCombustible(Combustible objcombustible) {

		try {

			String sql = "INSERT INTO "+ConexionBD.getNombre_BD()+".TBL_Combustibles(Nombre_Combustible)"
					+ " VALUES (?)";
			PreparedStatement ps = conn.prepareStatement(sql);

			
			ps.setString(1, objcombustible.getNombre_Combustible());
		
			ps.executeUpdate();

		} catch (SQLException e) {
			e.printStackTrace();
		}
	}	
		public void removeCombustible(int combustibleId) {
			try {
				String sql = "DELETE FROM "+ConexionBD.getNombre_BD()+".TBL_Combustibles WHERE combustibleId=?";
				PreparedStatement ps = conn.prepareStatement(sql);
				ps.setInt(1, combustibleId);
				ps.executeUpdate();

			} catch (SQLException e) {
				e.printStackTrace();
			}
		}

		public void editCombustible(Combustible objcombustible) {
			try {
				String sql = "UPDATE "+ConexionBD.getNombre_BD()+".TBL_Combustibles SET Nombre_Combustible=? "
						+ " WHERE combustibleId=?";
				PreparedStatement ps = conn.prepareStatement(sql);

				
				ps.setString(1, objcombustible.getNombre_Combustible());
				ps.setInt(2, objcombustible.getCombustibleId());
				ps.executeUpdate();

			} catch (SQLException e) {
				e.printStackTrace();
			}
		}

		public List<Combustible> getAllCombustibles() {
			List<Combustible> combustibles = new ArrayList<Combustible>();
			try {
				String sql = "SELECT * FROM "+ConexionBD.getNombre_BD()+".TBL_Combustibles";
				PreparedStatement ps = conn.prepareStatement(sql);
				ResultSet rs = ps.executeQuery();
				while (rs.next()) {
					Combustible objcombustible = new Combustible();
					objcombustible.setCombustibleId(rs.getInt("combustibleId"));
					objcombustible.setNombre_Combustible(rs.getString("Nombre_Combustible"));
					combustibles.add(objcombustible);
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}

			return combustibles;
		}

		public Combustible getCombustibleById(int combustibleId) {
			Combustible objcombustible= new Combustible();
			try {
				String sql = "SELECT * FROM "+ConexionBD.getNombre_BD()+".TBL_Combustibles WHERE combustibleId=?";
				PreparedStatement ps = conn.prepareStatement(sql);
				ps.setInt(1, combustibleId);
				ResultSet rs = ps.executeQuery();

				if (rs.next()) {
					objcombustible.setCombustibleId(rs.getInt("combustibleId"));
					objcombustible.setNombre_Combustible(rs.getString("Nombre_Combustible"));
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
			return objcombustible;
		}	
		
	

}

